package nongchang.kuaijiecaifu.com.ncapp_android.util;

import rx.Observable;
import rx.android.schedulers.AndroidSchedulers;
import rx.schedulers.Schedulers;

public class RxUtil {
    private static final String TAG = "RxUtil";

    public static <T> Observable.Transformer<T, T> schedulers() {
        return observable -> observable.subscribeOn(Schedulers.io())
                                       .observeOn(AndroidSchedulers.mainThread());
    }

}
